#include"../mqserver/mq_channel.hpp"

int main()
{
    xiang11mq::ChannelManager::ptr cmp = std::make_shared<xiang11mq::ChannelManager>();

    cmp->openChannel("c1", std::make_shared<xiang11mq::VirtualHost>("host1", "./data/host1", "./data/host1/host1.db"),
    std::make_shared<xiang11mq::ConsumerManager>(), xiang11mq::ProtobufCodecPtr(), 
    muduo::net::TcpConnectionPtr(), threadPool::ptr());

    return 0;
}